06b575093123e3642ed0972a60f169f5118fc27a,modules/tasks/tasks/src/main/java/org/motechproject/tasks/service/impl/TaskTriggerHandler.java,TaskTriggerHandler,handleRetry,#MotechEvent#,154

Before Change


    @Override
    @Transactional
    public void handleRetry(MotechEvent event) {
        if (!getIsHandled()) {
            setIsHandled(true);

            LOGGER.info("Handling the motech event with subject: {} for task retry", event.getSubject());

            Map<String, Object> eventParams = event.getParameters();
            Map<String, Object> eventMetadata = event.getMetadata();

            Task task = taskService.getTask((Long) eventMetadata.get(TASK_ID));

            if (task == null || !task.isEnabled()) {
                taskRetryHandler.unscheduleTaskRetry((String) eventMetadata.get(JOB_SUBJECT));
            } else {
                handleTask(task, eventParams, true);
            }

            setIsHandled(false);

After Change


            if (!isTaskHandled(task)) {
                addTaskHandled(task);

                handleTask(task, eventParams, true);

                deleteTaskHandled(task);
            }